package com.pzf.publish.controller;

import com.pzf.publish.service.PublishService;
import io.lettuce.core.dynamic.annotation.Param;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RestController;

/**
 * @Author: AdobePeng
 * @Date: 2021/3/9 16:48
 */

@RestController
public class RedisStreamController {
    @Autowired
    private PublishService publishService;
    @GetMapping("produceMsg")
    public void produceMsg(@Param("msg")String msg){
        publishService.test(msg);
    }
}
